670df8fd447f1dc4135952924fd0a519431e739e,src/main/java/com/couchbase/client/dcp/conductor/Conductor.java,Conductor,startStreamForPartition,#number#number#number#number#number#number#,191
Before Change
.toObservable();
}
})
.retryWhen(anyOf(NotConnectedException.class)
.delay(Delay.fixed(200, TimeUnit.MILLISECONDS))
.doOnRetry(new Action4<Integer, Throwable, Long, TimeUnit>() {
@Override
public void call(Integer integer, Throwable throwable, Long aLong, TimeUnit timeUnit) {
After Change
.toObservable();
}
})
.retryWhen(anyOf(NotConnectedException.class)
.max(Integer.MAX_VALUE)
.delay(Delay.fixed(200, TimeUnit.MILLISECONDS))
.doOnRetry(new Action4<Integer, Throwable, Long, TimeUnit>() {
@Override
public void call(Integer integer, Throwable throwable, Long aLong, TimeUnit timeUnit) {